cfg.setUseRpcServicePerComponent();
MiniCluster miniCluster = new MiniCluster(cfg);
executeJob(miniCluster);
}
@Test
MiniCluster miniCluster = new MiniCluster(cfg);
try {
miniCluster.start();
executeJob(miniCluster);
}
finally {
miniCluster.shutdown();